package com.SparkCore.RDD.Operator.Transform

import org.apache.spark.{SparkConf, SparkContext}

object Spark01_RDD_Operator_Transform {

  def main(args: Array[String]): Unit = {

    //创建环境
    val sparkConf = new SparkConf().setMaster("local[*]").setAppName("RDD")
    val sc = new SparkContext(sparkConf)

    //RDD算子 - map
    val rdd = sc.makeRDD(List(1,2,3,4))

    //写入转换函数
    def mapFunction(num: Int): Int = {
      num * 2
    }

    //val mapRDD = rdd.map(mapFunction)

    //val mapRDD = rdd.map((num : Int) => num + 2)
    //至简原则简化代码
    //val mapRDD = rdd.map((num : Int) => num + 2)
    //val mapRDD = rdd.map((num ) => num + 2)
    //val mapRDD = rdd.map(num => num + 2)
    val mapRDD = rdd.map(_ + 2)

    mapRDD.collect().foreach(println)

    //关闭
    sc.stop()

  }
}
